package com.szh.consumer.config;

import com.szh.common.constant.MQConstant;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
public class RabbitMqQueueConfig {
    
    @Bean
    public Queue quorumQueue(){
        return QueueBuilder.durable("quorum.queue.test").quorum().build();
    }
    
    @Bean
    public Queue helloJavaQueue(){
        return QueueBuilder.durable(MQConstant.HELLO_JAVA_QUEUE).build();
    }
}
